package com.xxpt.common.constant;


/**
 * rabbitMQ常量
 *
 * @autho wlf
 * @mender icetea
 */
public interface RabbitMqConstant {
    // exchange常量
    //public static final String EXCHANGE_TOPIC = "xxpt.topic";
    //public static final String DLX_NAME = "xxpt.dlx"; // 死信交换器

    // queue常量
    String QUEUE_ACTIVITY = "xxpt.activity";
    String DLQ_ACTIVITY = "xxpt.dlq.activity";

    String QUEUE_TEST01 = "xxpt.test01";
    String DLQ_TEST01 = "xxpt.dlq.test01"; //

    String QUEUE_TRAIN_RECORD = "xxpt.train.record";
    String DLQ_TRAIN_RECORD = "xxpt.dlq.train.record";

    String DELAYED_TEST01 = "xxpt.delayed.test01";
    String DELAYED_TEST01_ROUTING = "xxpt.delayed";
}